package com.supreme.simpleserver.component;

import org.springframework.stereotype.Component;

@Component
public class KafkaProducer {

    /*@Resource
    private KafkaTemplate<String, String> kafkaTemplate;

    public void sendMessage(String topic, JSONObject payload) {
        CompletableFuture<SendResult<String, String>> completableFuture = kafkaTemplate.send(topic, payload.toJSONString());
        completableFuture.whenComplete((stringResult, throwable) -> {
            System.out.println("stringResult = " + stringResult);
        });
    }*/
}
